package com.coffee.cmt.test;

import org.apache.flink.streaming.api.functions.sink.SinkFunction;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;

/**
 * @author songkui
 * @since 2024/6/20 10:14
 */
public class AccountAlertSink implements SinkFunction<AccountTransation> {

    /**
     *
     */
    private static final long serialVersionUID = 1L;
//    private static final Logger LOG = LoggerFactory.getLogger(AccountAlertSink.class);

    @Override
    public void invoke(AccountTransation value, Context context) {
        System.out.println(value.toString());
    }

}
